package com.yao.service;

import com.yao.websocket.WebSocketServer;
import org.slf4j.MDC;
import org.springframework.scheduling.annotation.Async;
import org.springframework.stereotype.Service;

import javax.annotation.Resource;

@Service
public class WebSocketService {

    @Resource
    private WebSocketServer webSocketServer;

    /**
     * @Async 声明该方法异步执行
     * 注意 @Async 会为所在类增加 Cglib 代理
     * @Async 声明的方法的调用方不能和自己在同一个类中
     */
    @Async
    public void sendInfo(String message , String logId) {
        MDC.put("LOG_ID", logId);
        webSocketServer.sendInfo(message);

    }
}